package com.atguigu.day02;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

// 并行度的设置
public class Example1 {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        // 设置全局并行度为1
        env.setParallelism(1);

        env
                .fromElements(1,2,3,4).setParallelism(1) // source算子的并行度是1,也就是说并行子任务的数量为1
                .map(r -> r * r).setParallelism(2)             // map算子的并行度是2,并行子任务的数量为2，要求map的2个并行子任务必须占用两个任务插槽
                .print();                                      // 由于print没有设置并行度，所以继承全局并行度

        env.execute();
    }
}
